//package bbkj.org.cn.demo;
//
//import java.math.BigDecimal;
//
//import org.apache.flink.api.common.functions.FilterFunction;
//import org.apache.flink.streaming.api.datastream.DataStream;
//import org.apache.flink.streaming.api.environment.LocalStreamEnvironment;
//
//import com.alibaba.fastjson.JSONObject;
//
//import lombok.Data;
//
//public class FilterDemo {
//	public static void main(String[] args) {
//		LocalStreamEnvironment lse = new LocalStreamEnvironment();
//		Item[] tmp = JSONObject.parseArray("[{'c1':12.31},"
//				+ "{'c1':13.29},"
//				+ "{'c1':14.62},"
//				+ "{'c1':14.46},"
//				+ "{'c1':14.30},"
//				+ "{'c1':15.09},"
//				+ "{'c1':15.39},"
//				+ "{'c1':16.87},"
//				+ "{'c1':18.02},"
//				+ "{'c1':18.43},"
//				+ "{'c1':20.27},"
//				+ "{'c1':22.30},"
//				+ "{'c1':20.89},"
//				+ "{'c1':18.8},"
//				+ "{'c1':16.92},"
//				+ "{'c1':16.08},"
//				+ "{'c1':15.86},"
//				+ "{'c1':15.40},"
//				+ "{'c1':14.90},"
//				+ "{'c1':15.18}]",Item.class).toArray(new Item[0]);
//		DataStream<Item> flintstones = lse.fromElements(tmp);
//		DataStream<Item> adults = flintstones.filter(new FilterFunction<Item>() {
//            /**
//			 * 
//			 */
//			private static final long serialVersionUID = -3814068875056389401L;
//
//			@Override
//            public boolean filter(Item person) throws Exception {
//                return person.getC1().compareTo(new BigDecimal(18))>0;
//            }
//        });
//
//		adults.print();
//        try {
//			lse.execute();
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//	}
//	@Data
//	public static class Item{
//		private BigDecimal c1;
//		private BigDecimal c15;
//	}
//}
